6d88f802dc7a0a6e3339339626924d612f641561,hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmnode/RMNodeImpl.java,ReconnectNodeTransition,transition,#RMNodeImpl#RMNodeEvent#,667
Before Change
if (rmNode.getState() != NodeState.UNHEALTHY) {
// Only add new node if old state is not UNHEALTHY
if (isDistributedRTEnabled &&
!rmNode.context.getGroupMembershipService().isLeader()) {
//Add NodeAddedSchedulerEvent to TransactionState
LOG.debug("HOP :: Added Pending event to TransactionState");
((TransactionStateImpl) event.getTransactionState()).
After Change
rmNode.setLastNodeHeartBeatResponseId(0);
if (rmNode.getState() != NodeState.UNHEALTHY) {
// Only add new node if old state is not UNHEALTHY
if (rmNode.context.isDistributedEnabled()) {
//Add NodeAddedSchedulerEvent to TransactionState
LOG.debug("HOP :: Added Pending event to TransactionState");
((TransactionStateImpl) event.getTransactionState()).